pub async fn handle_observe<H: ErrorHandler<W = IrohStreamWriter>>(
pair: StreamPair<H::R, H::W>,
store: Store,
request: ObserveRequest,
) -> Result<()>pub async fn handle_observe<H: ErrorHandler<W = IrohStreamWriter>>(
pair: StreamPair<H::R, H::W>,
store: Store,
request: ObserveRequest,
) -> Result<()>