File tree Expand file tree Collapse file tree 2 files changed +14
-7
lines changed Expand file tree Collapse file tree 2 files changed +14
-7
lines changed Original file line number Diff line number Diff line change 2
2
refs/heads/master: 61b1875c16de39c166b0f4d54bba19f9c6777d1a
3
3
refs/heads/snap-stage1: e33de59e47c5076a89eadeb38f4934f58a3618a6
4
4
refs/heads/snap-stage3: 4a81779abd786ff22d71434c6d9a5917ea4cdfff
5
- refs/heads/try: dc0b9f44e2731dec413d69997ad093962deb665e
5
+ refs/heads/try: 513d956dce5be849b69d1b3b4b7aa5c0252fcc1f
6
6
refs/tags/release-0.1: 1f5c5126e96c79d22cb7862f75304136e204f105
Original file line number Diff line number Diff line change @@ -101,12 +101,19 @@ fn pandoc_writer(
101
101
os:: close ( pipe_err. out ) ;
102
102
os:: close ( pipe_in. out ) ;
103
103
104
- let stdout = result:: get ( task:: try { ||
105
- readclose ( pipe_out. in )
106
- } ) ;
107
- let stderr = result:: get ( task:: try { ||
108
- readclose ( pipe_err. in )
109
- } ) ;
104
+ let stdout_po = comm:: port ( ) ;
105
+ let stdout_ch = comm:: chan ( stdout_po) ;
106
+ task:: spawn_sched ( task:: single_threaded) { ||
107
+ comm:: send ( stdout_ch, readclose ( pipe_out. in ) ) ;
108
+ }
109
+ let stdout = comm:: recv ( stdout_po) ;
110
+
111
+ let stderr_po = comm:: port ( ) ;
112
+ let stderr_ch = comm:: chan ( stderr_po) ;
113
+ task:: spawn_sched ( task:: single_threaded) { ||
114
+ comm:: send ( stderr_ch, readclose ( pipe_err. in ) ) ;
115
+ }
116
+ let stderr = comm:: recv ( stderr_po) ;
110
117
111
118
let status = run:: waitpid ( pid) ;
112
119
#debug ( "pandoc result: %i" , status) ;
You can’t perform that action at this time.
0 commit comments