Point-to-Point Communication API about kungfu HOT 1 CLOSED

diff --git a/srcs/go/rchannel/router.go b/srcs/go/rchannel/router.go
index cf12f72..8901e58 100644
--- a/srcs/go/rchannel/router.go
+++ b/srcs/go/rchannel/router.go
@@ -114,6 +114,16 @@ func (r *Router) stream(conn net.Conn, remote plan.NetAddr) (int, error) {
                        return i, err
                }
                r.monitor.Ingress(int64(msg.Length), remote)
-               r.bufferPool.require(remote.WithName(name)) <- msg
+               if isCollective(msg) {
+                       r.bufferPool.require(remote.WithName(name)) <- msg
+               } else {
+                       p2pCh <- msg
+                       // TODO: handler for p2pCh
+               }
        }
 }
+
+func isCollective(msg *Message) bool {
+       // TODO: determine msg type
+       return true
+}