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

Interface StreamFactory<RequestT,ResponseT>

All Known Subinterfaces:

StreamFactories.CursorStreamFactory, StreamFactories.PublishStreamFactory, StreamFactories.SubscribeStreamFactory

public interface StreamFactory<RequestT,ResponseT>

Method Summary

Modifier and Type	Method	Description
com.google.api.gax.rpc.ClientStream<RequestT>	New(com.google.api.gax.rpc.ResponseObserver<ResponseT> responseStream)

Method Detail

New

com.google.api.gax.rpc.ClientStream<RequestT> New(com.google.api.gax.rpc.ResponseObserver<ResponseT> responseStream)