Skip to content

Commit 2672758

Browse files
[feat] add support for arraybuffer (#62)
Closes #58
1 parent d3b4ae0 commit 2672758

File tree

2 files changed

+28
-2
lines changed

2 files changed

+28
-2
lines changed

package.json

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
},
1616
"dependencies": {
1717
"debug": "~2.6.4",
18-
"notepack.io": "~1.0.1",
18+
"notepack.io": "~2.1.0",
1919
"redis": "2.6.3",
2020
"socket.io-parser": "2.3.2"
2121
},
@@ -24,6 +24,6 @@
2424
"expect.js": "~0.3.1",
2525
"socket.io": "~2.0.1",
2626
"socket.io-client": "~2.0.1",
27-
"socket.io-redis": "~5.0.0"
27+
"socket.io-redis": "^5.1.0"
2828
}
2929
}

test/index.js

Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,32 @@ function client(srv, nsp, opts){
1919

2020
describe('emitter', function() {
2121
var srv;
22+
23+
it('should be able to emit any kind of data', function(done){
24+
srv = http();
25+
var sio = io(srv, {adapter: redisAdapter()});
26+
srv.listen();
27+
28+
var cli = client(srv, { forceNew: true });
29+
var emitter = ioe({ host: 'localhost', port: '6379' });
30+
31+
var buffer = new Buffer('asdfasdf', 'utf8');
32+
var arraybuffer = Uint8Array.of(1, 2, 3, 4).buffer;
33+
34+
cli.on('connect', function () {
35+
emitter.emit('payload', 1, '2', [3], buffer, arraybuffer);
36+
});
37+
38+
cli.on('payload', function(a, b, c, d, e) {
39+
expect(a).to.eql(1);
40+
expect(b).to.eql('2');
41+
expect(c).to.eql([3]);
42+
expect(d).to.eql(buffer);
43+
expect(e).to.eql(Buffer.from(arraybuffer)); // buffer on the nodejs client-side
44+
done();
45+
});
46+
});
47+
2248
describe('in namespaces', function(){
2349
beforeEach(function() {
2450
var pub = redis.createClient();

0 commit comments

Comments
 (0)