bind out write data API

Author: sbiscigl

crt/aws-c-http

@@ -10,6 +10,7 @@
 #include <aws/crt/Types.h>
 #include <aws/crt/io/Bootstrap.h>
 #include <aws/crt/io/SocketOptions.h>
+#include <aws/crt/io/Stream.h>
 #include <aws/crt/io/TlsOptions.h>
 
 #include <functional>
@@ -118,6 +119,11 @@ namespace Aws
                  * See `OnStreamComplete` for more info. This value can be empty.
                  */
                 OnStreamComplete onStreamComplete;
+
+                /**
+                 * See `UseManualDataWrites` for more info. If true the write data API must be used to provide data.
+                 */
+                bool UseManualDataWrites;
             };
 
             /**
@@ -216,6 +222,11 @@ namespace Aws
                  */
                 bool Activate() noexcept;
 
+                int WriteData(std::shared_ptr<Aws::Crt::Io::InputStream> stream,
+                    aws_http_stream_write_complete_fn* onComplete,
+                    void* userData,
+                    bool endStream = false) noexcept;
+
               private:
                 HttpClientStream(const std::shared_ptr<HttpClientConnection> &connection) noexcept;
 

include/aws/crt/http/HttpConnection.h

@@ -202,6 +202,7 @@ namespace Aws
                 options.on_response_headers = HttpStream::s_onIncomingHeaders;
                 options.on_response_header_block_done = HttpStream::s_onIncomingHeaderBlockDone;
                 options.on_complete = HttpStream::s_onStreamComplete;
+                options.use_manual_data_writes = requestOptions.UseManualDataWrites;
 
                 /* Do the same ref counting trick we did with HttpClientConnection. We need to maintain a reference
                  * internally (regardless of what the user does), until the Stream shuts down. */
@@ -361,6 +362,21 @@ namespace Aws
                 return true;
             }
 
+            int HttpClientStream::WriteData(std::shared_ptr<Aws::Crt::Io::InputStream> stream,
+                    aws_http_stream_write_complete_fn* onComplete,
+                    void* userData,
+                    bool endStream ) noexcept
+            {
+                struct aws_http_stream_write_data_options options;
+                AWS_ZERO_STRUCT(options);
+                options.data = stream->GetUnderlyingStream();
+                options.end_stream = endStream;
+                options.on_complete = onComplete;
+                options.user_data = userData;
+
+                return aws_http_stream_write_data(m_stream, &options);
+            }
+
             void HttpStream::UpdateWindow(std::size_t incrementSize) noexcept
             {
                 aws_http_stream_update_window(m_stream, incrementSize);