createDataStream method

  1. @override
Future<WsDataStream> createDataStream(
  1. DataStreamConfig config,
  2. CoordinationSession session
)
override

Creates a data stream with the given configuration and session context.

Implementation

@override
Future<WsDataStream> createDataStream(
  DataStreamConfig config,
  CoordinationSession session,
) async => WsDataStream(
  config: config,
  connection: connection,
  sessionName: session.config.name,
  streamNode: session.thisNode,
  clockOffsets: clockOffsets,
);