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.
```rust
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;
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().writeevent("hellostream".tostring(),
HashMap::new())?;
Ok(http::Response::ok())
}
```