@@ -1,13 +1,35 @@

-import { takeLatest, take, put } from "redux-saga/effects";

+import {} from "@redux-saga/is";

+import { channel, buffers } from "redux-saga";

+import { takeEvery, fork, takeLatest, take, put } from "redux-saga/effects";

 import { updateIp } from "./reducer";

+function* channelWorker(thing) {

+  console.log("the thing is:", thing);

+  yield;

+}

+

+function* channelListener(channel) {

+  console.log("hi from the listener");

+  yield takeEvery(channel, channelWorker);

+}

+

 export function* rootSaga() {

+  const myChannel = channel(buffers.sliding(10));

+

+  console.log("hi");

+  yield fork(channelListener, myChannel);

+

+  myChannel.put("hi");

+

   yield put({ type: "co/fwoar/APP_INIT" });

+  myChannel.put({ a: 3 });

   yield takeLatest("GET_IP", ipWorker);

   while (true) {

     yield take("FAIL");

     throw new Error("FAILURE!");

   }

+

+  yield appReady;

 }

 export function getIp() {