review.fuel-infra Code Review - packages/trusty/rabbitmq-server.git/blob

   1 -compile({parse_transform,pmod_pt}).
   2
   3 -module(sockjs_multiplex_channel, [Conn, Topic]).
   4
   5 -export([send/1, close/0, close/2, info/0]).
   6
   7 send(Data) ->
   8     Conn:send(iolist_to_binary(["msg", ",", Topic, ",", Data])).
   9
  10 close() ->
  11     close(1000, "Normal closure").
  12
  13 close(_Code, _Reason) ->
  14     Conn:send(iolist_to_binary(["uns", ",", Topic])).
  15
  16 info() ->
  17     Conn:info() ++ [{topic, Topic}].
  18