use crate::raw::*;
use crate::*;
pub enum TwoWays<ONE, TWO> {
One(ONE),
Two(TWO),
}
impl<ONE: oio::Read, TWO: oio::Read> oio::Read for TwoWays<ONE, TWO> {
async fn read_at(&self, offset: u64, limit: usize) -> Result<Buffer> {
match self {
TwoWays::One(v) => v.read_at(offset, limit).await,
TwoWays::Two(v) => v.read_at(offset, limit).await,
}
}
}
impl<ONE: oio::BlockingRead, TWO: oio::BlockingRead> oio::BlockingRead for TwoWays<ONE, TWO> {
fn read_at(&self, offset: u64, limit: usize) -> Result<Buffer> {
match self {
Self::One(v) => v.read_at(offset, limit),
Self::Two(v) => v.read_at(offset, limit),
}
}
}
impl<ONE: oio::Write, TWO: oio::Write> oio::Write for TwoWays<ONE, TWO> {
async fn write(&mut self, bs: Buffer) -> Result<usize> {
match self {
Self::One(v) => v.write(bs).await,
Self::Two(v) => v.write(bs).await,
}
}
async fn close(&mut self) -> Result<()> {
match self {
Self::One(v) => v.close().await,
Self::Two(v) => v.close().await,
}
}
async fn abort(&mut self) -> Result<()> {
match self {
Self::One(v) => v.abort().await,
Self::Two(v) => v.abort().await,
}
}
}
pub enum ThreeWays<ONE, TWO, THREE> {
One(ONE),
Two(TWO),
Three(THREE),
}
impl<ONE: oio::Read, TWO: oio::Read, THREE: oio::Read> oio::Read for ThreeWays<ONE, TWO, THREE> {
async fn read_at(&self, offset: u64, limit: usize) -> Result<Buffer> {
match self {
ThreeWays::One(v) => v.read_at(offset, limit).await,
ThreeWays::Two(v) => v.read_at(offset, limit).await,
ThreeWays::Three(v) => v.read_at(offset, limit).await,
}
}
}
impl<ONE: oio::BlockingRead, TWO: oio::BlockingRead, THREE: oio::BlockingRead> oio::BlockingRead
for ThreeWays<ONE, TWO, THREE>
{
fn read_at(&self, offset: u64, limit: usize) -> Result<Buffer> {
match self {
Self::One(v) => v.read_at(offset, limit),
Self::Two(v) => v.read_at(offset, limit),
Self::Three(v) => v.read_at(offset, limit),
}
}
}
impl<ONE: oio::Write, TWO: oio::Write, THREE: oio::Write> oio::Write
for ThreeWays<ONE, TWO, THREE>
{
async fn write(&mut self, bs: Buffer) -> Result<usize> {
match self {
Self::One(v) => v.write(bs).await,
Self::Two(v) => v.write(bs).await,
Self::Three(v) => v.write(bs).await,
}
}
async fn close(&mut self) -> Result<()> {
match self {
Self::One(v) => v.close().await,
Self::Two(v) => v.close().await,
Self::Three(v) => v.close().await,
}
}
async fn abort(&mut self) -> Result<()> {
match self {
Self::One(v) => v.abort().await,
Self::Two(v) => v.abort().await,
Self::Three(v) => v.abort().await,
}
}
}
pub enum FourWays<ONE, TWO, THREE, FOUR> {
One(ONE),
Two(TWO),
Three(THREE),
Four(FOUR),
}
impl<ONE, TWO, THREE, FOUR> oio::Read for FourWays<ONE, TWO, THREE, FOUR>
where
ONE: oio::Read,
TWO: oio::Read,
THREE: oio::Read,
FOUR: oio::Read,
{
async fn read_at(&self, offset: u64, limit: usize) -> Result<Buffer> {
match self {
FourWays::One(v) => v.read_at(offset, limit).await,
FourWays::Two(v) => v.read_at(offset, limit).await,
FourWays::Three(v) => v.read_at(offset, limit).await,
FourWays::Four(v) => v.read_at(offset, limit).await,
}
}
}
impl<ONE, TWO, THREE, FOUR> oio::BlockingRead for FourWays<ONE, TWO, THREE, FOUR>
where
ONE: oio::BlockingRead,
TWO: oio::BlockingRead,
THREE: oio::BlockingRead,
FOUR: oio::BlockingRead,
{
fn read_at(&self, offset: u64, limit: usize) -> Result<Buffer> {
match self {
Self::One(v) => v.read_at(offset, limit),
Self::Two(v) => v.read_at(offset, limit),
Self::Three(v) => v.read_at(offset, limit),
Self::Four(v) => v.read_at(offset, limit),
}
}
}
impl<ONE, TWO, THREE, FOUR> oio::List for FourWays<ONE, TWO, THREE, FOUR>
where
ONE: oio::List,
TWO: oio::List,
THREE: oio::List,
FOUR: oio::List,
{
async fn next(&mut self) -> Result<Option<oio::Entry>> {
match self {
Self::One(v) => v.next().await,
Self::Two(v) => v.next().await,
Self::Three(v) => v.next().await,
Self::Four(v) => v.next().await,
}
}
}
impl<ONE, TWO, THREE, FOUR> oio::BlockingList for FourWays<ONE, TWO, THREE, FOUR>
where
ONE: oio::BlockingList,
TWO: oio::BlockingList,
THREE: oio::BlockingList,
FOUR: oio::BlockingList,
{
fn next(&mut self) -> Result<Option<oio::Entry>> {
match self {
Self::One(v) => v.next(),
Self::Two(v) => v.next(),
Self::Three(v) => v.next(),
Self::Four(v) => v.next(),
}
}
}