(
requests_message: RequestsMessage,
env: Environment,
output_options: OutputOptions,
processing_options: ProcessingOptions,
extra_stream_kwargs: Optional[Dict[str, Any]] = None
)
| 25 | |
| 26 | |
| 27 | def write_message( |
| 28 | requests_message: RequestsMessage, |
| 29 | env: Environment, |
| 30 | output_options: OutputOptions, |
| 31 | processing_options: ProcessingOptions, |
| 32 | extra_stream_kwargs: Optional[Dict[str, Any]] = None |
| 33 | ): |
| 34 | if not output_options.any(): |
| 35 | return |
| 36 | write_stream_kwargs = { |
| 37 | 'stream': build_output_stream_for_message( |
| 38 | env=env, |
| 39 | requests_message=requests_message, |
| 40 | output_options=output_options, |
| 41 | processing_options=processing_options, |
| 42 | extra_stream_kwargs=extra_stream_kwargs |
| 43 | ), |
| 44 | # NOTE: `env.stdout` will in fact be `stderr` with `--download` |
| 45 | 'outfile': env.stdout, |
| 46 | 'flush': env.stdout_isatty or processing_options.stream |
| 47 | } |
| 48 | try: |
| 49 | if env.is_windows and 'colors' in processing_options.get_prettify(env): |
| 50 | write_stream_with_colors_win(**write_stream_kwargs) |
| 51 | else: |
| 52 | write_stream(**write_stream_kwargs) |
| 53 | except OSError as e: |
| 54 | if processing_options.show_traceback and e.errno == errno.EPIPE: |
| 55 | # Ignore broken pipes unless --traceback. |
| 56 | env.stderr.write('\n') |
| 57 | else: |
| 58 | raise |
| 59 | |
| 60 | |
| 61 | def write_stream( |
no test coverage detected