Uses of Interface
com.google.cloud.pubsublite.internal.wire.StreamFactory

Packages that use StreamFactory

Package	Description
com.google.cloud.pubsublite.internal.wire

Uses of StreamFactory in com.google.cloud.pubsublite.internal.wire

Subinterfaces of StreamFactory in com.google.cloud.pubsublite.internal.wire

Modifier and Type	Interface	Description
static interface	StreamFactories.CursorStreamFactory
static interface	StreamFactories.PublishStreamFactory
static interface	StreamFactories.SubscribeStreamFactory

Methods in com.google.cloud.pubsublite.internal.wire with parameters of type StreamFactory

Modifier and Type	Method	Description
ConnectionT	SingleConnectionFactory.New(StreamFactory<StreamRequestT,StreamResponseT> streamFactory, com.google.api.gax.rpc.ResponseObserver<ClientResponseT> clientStream, StreamRequestT initialRequest)

Constructors in com.google.cloud.pubsublite.internal.wire with parameters of type StreamFactory

Constructor	Description
CommitterImpl(StreamFactory<StreamingCommitCursorRequest,StreamingCommitCursorResponse> streamFactory, InitialCommitCursorRequest request)
SingleConnection(StreamFactory<StreamRequestT,StreamResponseT> streamFactory, com.google.api.gax.rpc.ResponseObserver<ClientResponseT> clientStream)
SingleConnection(StreamFactory<StreamRequestT,StreamResponseT> streamFactory, com.google.api.gax.rpc.ResponseObserver<ClientResponseT> clientStream, Duration streamIdleTimeout)