wasmcloud-actor-eventstreams 0.1.1

[![crates.io](https://img.shields.io/crates/v/wasmcloud-actor-eventstreams.svg)](https://crates.io/crates/wasmcloud-actor-eventstreams) 
![Rust](https://img.shields.io/github/workflow/status/wasmcloud/actor-interfaces/Event%20Streams)
![license](https://img.shields.io/crates/l/wasmcloud-actor-eventstreams.svg) 
[![documentation](https://docs.rs/wasmcloud-actor-eventstreams/badge.svg)](https://docs.rs/wasmcloud-actor-eventstreams)
# 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
extern crate wasmcloud_actor_eventstreams as streams;
use wapc_guest::HandlerResult;
use streams::StreamQuery;
use std::collections::HashMap;

#[no_mangle]
pub fn wapc_init() {
    streams::Handlers::register_deliver_event(deliver_event);
    wasmcloud_actor)core::Handlers::register_health_request(health);
}

fn deliver_event(event: streams::Event) -> HandlerResult<bool> {
   // process event, query streams, or send new events...
   let _evts_so_far = streams::default()
      .query_stream(StreamQuery{
          stream_id: event.stream_id.to_string(),
          range: None,
          count: 0                   
   });
   let _eid = streams::default().write_event("hello_streams".to_string(),
         HashMap::new());
   Ok(true)
}
```