Oleksii Shpylchyn lxii

Redux WebSocket Middleware: Example

This Gist provides some code examples of how to implement WebSocket stream handling using a Redux middleware. Please be aware that this is only provided as an example and that critical things like exception handling have not been implemented.

A more complete version has been packaged, tested, and is available on GitHub as redux-websocket. This library has also been published to npm at @giantmachines/redux-websocket.

Middleware

This module represents the foundation of the middleware and implements the ideas presented above. The exported function is used during the creation of the Redux store (see the following snippet).

	# Takes an ordered vector of numeric values and returns a small bar chart made
	# out of Unicode block elements. Works well inside dplyr mutate() or summarise()
	# calls on grouped data frames.

	sparkbar <- function(values) {
	span <- max(values) - min(values)
	if(span > 0 & !is.na(span)) {
	steps <- round(values / (span / 7))
	blocks <- c('▁', '▂', '▃', '▄', '▅', '▆', '▇', '█')
	paste(sapply(steps - (min(steps) - 1), function(i) blocks[i]), collapse = '')

	// Gist for https://medium.com/@ebakhtarov/bidirectional-websockets-with-redux-saga

	import { eventChannel } from "redux-saga";
	import { all, call, put, take, select, race } from "redux-saga/effects";

	import { actionTypes } from "./constants";

	function watchMessages(socket) {
	return eventChannel(emit => {
	/* eslint-disable no-param-reassign */