Module changes 

JMAP Email/changes coroutine (RFC 8621 §4.3): wraps the generic JmapChanges with the JMAP-Mail capability set.

Example

use std::{
    io::{Read, Write},
    net::TcpStream,
};

use io_jmap::{
    coroutine::{JmapCoroutine, JmapCoroutineState, JmapYield},
    rfc8620::session::JmapSession,
    rfc8621::email::changes::{JmapEmailChanges, JmapEmailChangesOptions},
};
use secrecy::SecretString;

// Ready stream needed (TCP-connected, TLS-negociated)
let mut stream = TcpStream::connect("api.example.com:443").unwrap();
let mut buf = [0u8; 4096];

let session: JmapSession = serde_json::from_str(r#"{
    "username": "",
    "accounts": {},
    "primaryAccounts": {"urn:ietf:params:jmap:mail": "a1"},
    "capabilities": {},
    "apiUrl": "https://api.example.com/jmap/",
    "downloadUrl": "",
    "uploadUrl": "",
    "eventSourceUrl": "",
    "state": ""
}"#).unwrap();
let auth = SecretString::from("Bearer xyz");
let mut coroutine =
    JmapEmailChanges::new(&session, &auth, "s1", JmapEmailChangesOptions::default()).unwrap();
let mut arg = None;

let out = loop {
    match coroutine.resume(arg.take()) {
        JmapCoroutineState::Yielded(JmapYield::WantsWrite(bytes)) => {
            stream.write_all(&bytes).unwrap();
        }
        JmapCoroutineState::Yielded(JmapYield::WantsRead) => {
            let n = stream.read(&mut buf).unwrap();
            arg = Some(&buf[..n]);
        }
        JmapCoroutineState::Complete(Ok(out)) => break out,
        JmapCoroutineState::Complete(Err(err)) => panic!("{err}"),
    }
};

println!("new state {}", out.new_state);

Structs

JmapEmailChanges

I/O-free coroutine for the JMAP Email/changes method.

JmapEmailChangesOptions

Options for JmapEmailChanges::new.

Enums

JmapEmailChangesError

Failure causes during a JMAP Email/changes flow.