So i have been trying to convert my EditText input that i get from my TextWatcher to an observable of stream but i cannot convert it.

I am trying the following

```
etSearch.addTextChangedListener(object: TextWatcher{
        override fun afterTextChanged(p0: Editable?) {
            //I want to create an observable here to send events
               Observable.create(e->e.next(p0));
        }

        override fun beforeTextChanged(p0: CharSequence?, p1: Int, p2: Int, p3: Int) {

        }

        override fun onTextChanged(p0: CharSequence?, p1: Int, p2: Int, p3: Int) {

        }
    })

```

I am not able to figure out where i should create my events so that i am able to subscribe to it.