`eventstoredb.client.subscribe_to_stream.grpc`#

Module Contents#

`create_subscribe_to_stream_request`(stream_name, options)
`convert_subscribe_to_stream_response`(message)
`convert_read_response_subscription_confirmation`(message)

eventstoredb.client.subscribe_to_stream.grpc.create_subscribe_to_stream_request(stream_name, options)[source]#

Parameters:

stream_name (str) –
options (eventstoredb.client.subscribe_to_stream.types.SubscribeToStreamOptions) –

Return type:

eventstoredb.generated.event_store.client.streams.ReadReq

eventstoredb.client.subscribe_to_stream.grpc.convert_subscribe_to_stream_response(message)[source]#

Parameters:: message (eventstoredb.generated.event_store.client.streams.ReadResp) –
Return type:: eventstoredb.events.ReadEvent | eventstoredb.events.CaughtUp | eventstoredb.events.FellBehind | eventstoredb.client.subscribe_to_stream.types.SubscriptionConfirmation

eventstoredb.client.subscribe_to_stream.grpc.convert_read_response_subscription_confirmation(message)[source]#

Parameters:: message (eventstoredb.generated.event_store.client.streams.ReadRespSubscriptionConfirmation) –
Return type:: eventstoredb.client.subscribe_to_stream.types.SubscriptionConfirmation