56
executableTaskConverter ExecutableTaskConverter,
57
enableStreaming bool,
59
>
return &StreamReceiverMonitorImpl{
60
>
ProcessToolBox: processToolBox,
61
>
executableTaskConverter: executableTaskConverter,
62
>
enableStreaming: enableStreaming,
63
>
64
>
status: streamStatusInitialized,
65
>
shutdownOnce: channel.NewShutdownOnce(),
66
>
67
>
inboundStreams: make(map[ClusterShardKeyPair]StreamSender),
68
>
outboundStreams: make(map[ClusterShardKeyPair]StreamReceiver),
69
>
}
70
>
}
71
72
func (m *StreamReceiverMonitorImpl) Start() {