The core libraries of the teknek stream processing platform