Method from_env

src/droidplug/jni_utils/stream.rs:27–42

(env: &'b JNIEnv<'a>, obj: JObject<'a>)

impl<'a: 'b, 'b> JStream<'a, 'b> {
    pub fn from_env(env: &'b JNIEnv<'a>, obj: JObject<'a>) -> Result<Self> {
        let poll_next = env.get_method_id(
            JClass::from(
                super::classcache::get_class("io/github/gedgygedgy/rust/stream/Stream")
                    .unwrap()
                    .as_obj(),
            ),
            "pollNext",
            "(Lio/github/gedgygedgy/rust/task/Waker;)Lio/github/gedgygedgy/rust/task/PollResult;",
        )?;
        Ok(Self {
            internal: obj,
            poll_next,
            env,
        })
    }

    fn j_poll_next(&self, waker: JObject<'a>) -> Result<Poll<Option<JObject<'a>>>> {
        let result = self