static channel_T *
get_channel_arg(typval_T *tv)
{
- channel_T *channel;
+ channel_T *channel = NULL;
- if (tv->v_type != VAR_CHANNEL)
+ if (tv->v_type == VAR_JOB)
+ {
+ if (tv->vval.v_job != NULL)
+ channel = tv->vval.v_job->jv_channel;
+ }
+ else if (tv->v_type == VAR_CHANNEL)
+ {
+ channel = tv->vval.v_channel;
+ }
+ else
{
EMSG2(_(e_invarg2), get_tv_string(tv));
return NULL;
}
- channel = tv->vval.v_channel;
if (channel == NULL || !channel_is_open(channel))
{
* "job_start()" function
*/
static void
-f_job_start(typval_T *argvars UNUSED, typval_T *rettv)
+f_job_start(typval_T *argvars, typval_T *rettv)
{
job_T *job;
char_u *cmd = NULL;
let job = job_start(s:python . " test_channel_pipe.py", {'mode': 'raw'})
call assert_equal("run", job_status(job))
try
- let handle = job_getchannel(job)
- call ch_sendraw(handle, "echo something\n")
- let msg = ch_readraw(handle)
+ " For a change use the job where a channel is expected.
+ call ch_sendraw(job, "echo something\n")
+ let msg = ch_readraw(job)
call assert_equal("something\n", substitute(msg, "\r", "", 'g'))
- call ch_sendraw(handle, "double this\n")
- let msg = ch_readraw(handle)
+ call ch_sendraw(job, "double this\n")
+ let msg = ch_readraw(job)
call assert_equal("this\nAND this\n", substitute(msg, "\r", "", 'g'))
- let reply = ch_evalraw(handle, "quit\n", {'timeout': 100})
+ let reply = ch_evalraw(job, "quit\n", {'timeout': 100})
call assert_equal("Goodbye!\n", substitute(reply, "\r", "", 'g'))
finally
call job_stop(job)