Streamed read for binary HTTP

.gitignore

@@ -3,3 +3,4 @@
 *~
 *.swp
 /.vscode/
+/mutants.out*/

Cargo.toml

@@ -6,5 +6,5 @@ members = [
   "ohttp",
   "ohttp-client",
   "ohttp-client-cli",
-  "ohttp-server",
+  "ohttp-server", "sync-async",
 ]

bhttp-convert/Cargo.toml

@@ -9,4 +9,4 @@ structopt = "0.3"
 
 [dependencies.bhttp]
 path= "../bhttp"
-features = ["bhttp", "http"]
+features = ["http"]

bhttp-convert/src/main.rs

@@ -1,11 +1,12 @@
 #![deny(warnings, clippy::pedantic)]
 
-use bhttp::{Message, Mode};
 use std::{
     fs::File,
     io::{self, Read},
     path::PathBuf,
 };
+
+use bhttp::{Message, Mode};
 use structopt::StructOpt;
 
 #[derive(Debug, StructOpt)]

bhttp/Cargo.toml

@@ -9,17 +9,18 @@ description = "Binary HTTP messages (RFC 9292)"
 repository = "https://github.com/martinthomson/ohttp"
 
 [features]
-default = ["bhttp"]
-bhttp = ["read-bhttp", "write-bhttp"]
-http = ["read-http", "write-http"]
-read-bhttp = []
-write-bhttp = []
-read-http = ["url"]
-write-http = []
+default = []
+http = ["dep:url"]
+stream = ["dep:futures", "dep:pin-project"]
 
 [dependencies]
+futures = {version = "0.3", optional = true}
+pin-project = {version = "1.1", optional = true}
 thiserror = "1"
 url = {version = "2", optional = true}
 
 [dev-dependencies]
 hex = "0.4"
+
+[dev-dependencies.sync-async]
+path= "../sync-async"

bhttp/src/err.rs

@@ -1,14 +1,9 @@
-use thiserror::Error;
-
-#[derive(Error, Debug)]
+#[derive(thiserror::Error, Debug)]
 pub enum Error {
     #[error("a request used the CONNECT method")]
     ConnectUnsupported,
     #[error("a field contained invalid Unicode: {0}")]
     CharacterEncoding(#[from] std::string::FromUtf8Error),
-    #[error("a chunk of data of {0} bytes is too large")]
-    #[cfg(feature = "stream")]
-    ChunkTooLarge(u64),
     #[error("read a response when expecting a request")]
     ExpectedRequest,
     #[error("read a request when expecting a response")]
@@ -19,8 +14,14 @@ pub enum Error {
     InvalidMode,
     #[error("the status code of a response needs to be in 100..=599")]
     InvalidStatus,
+    #[cfg(feature = "stream")]
+    #[error("a method was called when the message was in the wrong state")]
+    InvalidState,
     #[error("IO error {0}")]
     Io(#[from] std::io::Error),
+    #[cfg(feature = "stream")]
+    #[error("the size of a vector exceeded the limit that was set")]
+    LimitExceeded,
     #[error("a field or line was missing a necessary character 0x{0:x}")]
     Missing(u8),
     #[error("a URL was missing a key component")]
@@ -34,14 +35,8 @@ pub enum Error {
     #[error("a message included the Upgrade field")]
     UpgradeUnsupported,
     #[error("a URL could not be parsed into components: {0}")]
-    #[cfg(feature = "read-http")]
+    #[cfg(feature = "http")]
     UrlParse(#[from] url::ParseError),
 }
 
-#[cfg(any(
-    feature = "read-http",
-    feature = "write-http",
-    feature = "read-bhttp",
-    feature = "write-bhttp"
-))]
 pub type Res<T> = Result<T, Error>;