crates.io Rust license documentation

wasmCloud Event Streams Actor Interface

This crate provides an abstraction over the wasmcloud:eventstreams contract. This allows actors to write immutable events to a stream, receive events from a stream, and query events from a stream.

Example

```rust

[macro_use]

extern crate wasmcloudactorcore as actor; extern crate wasmcloudactoreventstreams as streams; extern crate wasmcloudactorhttp_server as http;

use wapc_guest::HandlerResult; use streams::*; use std::collections::HashMap;

[actor::init]

fn init() { http::Handlers::registerhandlerequest(handle_request); }

fn handlerequest(req: http::Request) -> HandlerResulthttp::Response { // process event, query streams, or send new events... let evtssofar = streams::default() .querystream(StreamQuery{ streamid: "hellostream".tostring(), range: None, count: 0
}); let ack = streams::default().write
event("hellostream".tostring(), HashMap::new())?; Ok(http::Response::ok()) } ```