StreamStatusManager

constructor(feeds: List<Feed>, emit: (AirbyteStreamStatusTraceMessage) -> Unit)