convert skypipe_input_stream to class