pub type SubscriptionHandlerFn = Arc<dyn Fn(Value) -> BoxFuture<Result<BoxStream<Result<Value, SeamError>>, SeamError>> + Send + Sync>;
pub struct SubscriptionHandlerFn { /* private fields */ }