Rework part of the lib to be more versatile

example/actions/image.js

@@ -1,13 +1,13 @@
 'use strict';
 
-const {Stream} = require ('../..');
+const {Stream, withType} = require ('../..');
 const Future = require ('fluture');
 const fs = require ('fs');
 const path = require ('path');
 
 const access = x => y => Future.node (c => fs.access (x, y, c));
 
-module.exports = req => Future.go (function* () {
+module.exports = _ => req => Future.go (function* () {
   if (!req.query.file) {
     yield Future.reject (
       new Error ('You need to provide a query named "file"')
@@ -24,7 +24,6 @@ module.exports = req => Future.go (function* () {
     (_ => new Error ('No read access to the requested file'))
     (access (file) (fs.constants.R_OK));
 
-  return Stream (200)
-                (path.extname (req.query.file))
-                (fs.createReadStream (file));
+  return withType (path.extname (req.query.file))
+                  (Stream (Future.encase (fs.createReadStream) (file)));
 });

example/actions/session.js

@@ -3,7 +3,7 @@
 const {Next} = require ('../..');
 const Future = require ('fluture');
 
-module.exports = (req, locals) => {
+module.exports = locals => req => {
   const session = {id: req.headers['x-authenticated-user']};
   const newLocals = Object.assign ({session}, locals);
   return Future.resolve (Next (newLocals));

example/actions/welcome.js

@@ -3,7 +3,7 @@
 const {Render} = require ('../..');
 const Future = require ('fluture');
 
-module.exports = (req, locals) => {
+module.exports = locals => _ => {
   const user = locals.session.id ? `user ${locals.session.id}` : 'stranger';
-  return Future.resolve (Render (200) ('index') ({user}));
+  return Future.resolve (Render ('index') ({user}));
 };

example/actions/welcomeJson.js

@@ -3,7 +3,7 @@
 const {Json} = require ('../..');
 const Future = require ('fluture');
 
-module.exports = (req, locals) => {
+module.exports = locals => _ => {
   const welcome = locals.session.id ? `user ${locals.session.id}` : 'stranger';
-  return Future.resolve (Json (200) ({welcome}));
+  return Future.resolve (Json ({welcome}));
 };