Function run_adapter

pub async fn run_adapter<D, I, O, E>(
    input: I,
    output: O,
    adapter_factory: impl FnOnce(UnboundedSender<Either<ProtocolMessage, <D as DebugAdapter>::Message>>) -> D,
) -> Result<(), DebugAdapterError<E, <O as Sink<ProtocolMessage>>::Error, <D as DebugAdapter>::CustomError>>
where
    D: DebugAdapter + Send + 'static,
    I: Stream<Item = Result<ProtocolMessage, E>> + Unpin + Send + 'static,
    O: Sink<ProtocolMessage> + Unpin + Send + 'static,
    E: Send + 'static,
    <O as Sink<ProtocolMessage>>::Error: Send + 'static,
    <D as DebugAdapter>::CustomError: Send + 'static,