defproc my_source (chan!(int) X)
{
   chp {
      X!0; X!4; X!3 
   }
}

defproc my_sink (chan?(int) X)
{
   int x;
   chp {
      *[ X?x; log ("received ", x) ]
   }
}   

defproc test()
{
    my_source s;
    my_sink t(s.X);
}