Function massa_grpc::stream::send_operations::send_operations

source ยท
pub(crate) async fn send_operations(
    grpc: &MassaPublicGrpc,
    request: Request<Streaming<SendOperationsRequest>>,
) -> Result<SendOperationsStreamType, GrpcError>
Expand description

This function takes a streaming request of operations messages, verifies, saves and propagates the operations received in each message, and sends back a stream of operations ids messages