| 974 | } |
| 975 | |
| 976 | static struct io_plan *rpc_conn_write_request(struct io_conn *conn, |
| 977 | struct plugin *plugin) |
| 978 | { |
| 979 | struct jstream *jstr = list_top(&plugin->rpc_js_list, struct jstream, list); |
| 980 | if (jstr) |
| 981 | return json_stream_output(jstr->js, conn, |
| 982 | rpc_stream_complete, plugin); |
| 983 | |
| 984 | return io_out_wait(conn, plugin->io_rpc_conn, |
| 985 | rpc_conn_write_request, plugin); |
| 986 | } |
| 987 | |
| 988 | static struct io_plan *rpc_conn_init(struct io_conn *conn, |
| 989 | struct plugin *plugin) |
no outgoing calls
no test coverage detected