(
env: Environment,
data: Any,
*,
processing_options: Optional[ProcessingOptions] = None,
headers: Optional[HTTPHeadersDict] = None,
stream_kwargs: Optional[Dict[str, Any]] = None
)
| 98 | |
| 99 | |
| 100 | def write_raw_data( |
| 101 | env: Environment, |
| 102 | data: Any, |
| 103 | *, |
| 104 | processing_options: Optional[ProcessingOptions] = None, |
| 105 | headers: Optional[HTTPHeadersDict] = None, |
| 106 | stream_kwargs: Optional[Dict[str, Any]] = None |
| 107 | ): |
| 108 | msg = requests.PreparedRequest() |
| 109 | msg.is_body_upload_chunk = True |
| 110 | msg.body = data |
| 111 | msg.headers = headers or HTTPHeadersDict() |
| 112 | msg_output_options = OutputOptions.from_message(msg, body=True, headers=False) |
| 113 | return write_message( |
| 114 | requests_message=msg, |
| 115 | env=env, |
| 116 | output_options=msg_output_options, |
| 117 | processing_options=processing_options or ProcessingOptions(), |
| 118 | extra_stream_kwargs=stream_kwargs |
| 119 | ) |
| 120 | |
| 121 | |
| 122 | def build_output_stream_for_message( |
no test coverage detected