Started writing APIs to manage streams