package Ġchat . rocket . core . internal . realtime . socket . message . collection Ċ Ċ import Ġchat . rocket . core . internal . realtime . socket . Socket Ċ import Ġkotlinx . coroutines . experimental . launch Ċ import Ġorg . json . JSONObject Ċ Ċ internal Ġconst Ġval ĠST REAM _ NOTIFY _ ROOM Ġ= Ġ" stream - notify - room " Ċ Ċ internal Ġfun ĠSocket . process Notify Room Stream ( text : ĠString ) Ġ{ ĊĠĠĠ Ġtry Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġjson Ġ= ĠJSONObject ( text ) ĊĠĠĠĠĠĠĠ Ġval Ġfields Ġ= Ġjson . getJSONObject (" fields ") ĊĠĠĠĠĠĠĠ Ġval Ġarray Ġ= Ġfields . get JSONArray (" args ") ĊĊĠĠĠĠĠĠĠ Ġlaunch ( parent Ġ= Ġparent Job ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġtyping Status Channel . send ( Pair ( array . getString ( 0 ), Ġarray . getBoolean ( 1 ))) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ġcatch Ġ( ex : ĠException ) Ġ{ ĊĠĠĠĠĠĠĠ Ġex . printStackTrace () ĊĠĠĠ Ġ} Ċ }