Ballerina workers sample

workers.bal

import ballerina/io;

function main(string... args) {

    stream<string> userInput;

    fork {        
        worker stdin_read {
            while(true) {
                io:println("Type something:");
                string s = io:readln(());                
                userInput.publish(s);
            }            
        }        
        
        worker echo1 {
            userInput.subscribe((string s) => {
                string smod = "[ECHO 1] " + s;               
                io:println(smod);
            });            
        }        

        worker echo2 {
            userInput.subscribe((string s) => {
                string smod = "[ECHO 2] " + s;
                io:println(smod);
            });
        }
    } join(all) (map results) {

    }
}