async-io-bridge

A compat wrapper around std::io::{Read, Write, Seek} that implements tokio::io::{AsyncRead, AsyncWrite, AsyncSeek}.

See tokio-io-compat if you want to wrap async io objects to provide sync interfaces.

Notice

Never consume the wrapped io object in the same thread as its original one, or you will get a deadlock.

Example

```rust use std::io::{Cursor, Read, Seek, SeekFrom, Write}; use asynciobridge::BridgeBuilder;

let mut asyncio = Cursor::new(vec![]); // some async io object // Bridge all io traits you need. let (fut, mut syncio) = BridgeBuilder::new(asyncio) .bridgeread() .bridgewrite() .bridgeseek() .build();

// Spawn the bridge future to provide data to the sync io wrapper. let bridgehandler = tokio::task::spawn(fut); // Do anything you want with the sync io wrapper in a separate blocking thread. let blockinghandler = tokio::task::spawnblocking(move || { syncio.writeall(&[0, 1, 2, 3, 4]).unwrap(); syncio.seek(SeekFrom::Start(2)).unwrap();

let mut buffer = [0; 1];
sync_io.read_exact(&mut buffer).unwrap();
assert_eq!(&buffer, &[2]);

});

blockinghandler.await.unwrap(); bridgehandler.await.unwrap(); ```