Reactive Streamsとは？ - たけぞう瀕死ブログ
Reactive Streamsというのはノンブロッキングなback pressure可能な非同期ストリーム処理の標準的な仕様を提供しようというもので、実装としてはAkka Streams、RxJava、Reactor Composable、Ratpackなどがあります。 Reactive StreamsについてはAkkaのコミッタであるKonrad Malawskiさんの以下のスライドがとてもわかりやすいです。 2014 akka-streams-tokyo-japanese from Konrad Malawski ストリーム処理（というか非同期メッセージング全般に言えることですが）では受信側の処理能力を超えるデータを送信し続けるといずれキャパシティを超えてオーバーフローが発生してしまうため、送信側に比べて受信側の処理能力が低い場合は送信側が手加減してデータを送信する必要があります。な
第27回 JSONデータを扱うためのJavaライブラリ「Jackson Java JSON-processor」 | gihyo.jp
「Jackson Java JSON-processor」とは 近年のWebアプリケーション開発では、JSONが必須の技術になっています。クライアントサイドで利用されるJavaScriptで容易に扱えることから、Webサーバとのデータ交換のためのフォーマットとして広く利用されているからです。Javaアプリケーションも例外ではなく、次期Java EE仕様であるJava EE 7（JSR 343として仕様策定中）にもJSONを扱うためのAPIが標準で取り込まれる見込みになっています。 それに伴い、Java用のJSON APIの標準仕様についても、JSR 353として標準化プロセスに入っています。その他にも、すでにJavaでJSONを扱うための様々なライブラリが存在しています。中でも「Jackson Java JSON-processor」や「google-json」はJSR 353にも既存実装
Stream API がブラウザにやってくる - Block Rockin’ Codes
Intro 今日は、フロントのプログラミングスタイルに、にまた一つ大きな変化をもたらすであろう Stream という API についてです。 この仕様は現時点でまだ策定中であるため、 API は変更される恐れがある点にご注意ください。 Stream API 以前 「Node.js の Stream API で「データの流れ」を扱う方法」 という記事を書きましたが、簡単に言うとあれがブラウザにもやってくるという話です。 非同期処理おさらい もう何度も書いた話なので駆け足で。 JS はシングルスレッドでイベント駆動な世界なので、何をするにも非同期であり、コールバックを登録することで完了した結果を受け取る API が基本です。 これは、ブラウザの DOM の API でも、 Node.js でも共通しています。 概念を疑似コードで書くと以下のような感じです。 console.log('1');
ストリーム表現とその変換 - ✘╹◡╹✘
データをストリームとして表現する方法と、ストリームを変換する方法を紹介する。 ストリームはメッセージが流れる川である Pub/Subメッセージングモデルでメッセージを流すためのオブジェクトのことをストリームと呼ぶことにする。ストリームにはメッセージをPublishでき、またメッセージを受け取ったときの処理をSubscribeできる。例えばキーボードからの入力をPublishして、内容をコンソールに出力するような処理をSubscribeできる。 kamo.jsでストリームを表現する ストリームについて説明するために、kamo.jsというストリームを表現するためのライブラリをつくった。kamo.jsは、ストリームを作成するためのkamo.Streamというコンストラクタ関数を提供する。このコンストラクタ関数から作成されたオブジェクトは、publishとsubscribeというメソッド(※プロパ
非同期ストリーム処理の標準化を目指す "Reactive Streams" とは - Okapies' Archive
TL でこんなのが流れてたので少し調べてみた。 Learn about the Reactive Streams initiative & how we're supporting a standard for asynch stream processing on the JVM http://t.co/5wUF0PjTBe— Twitter Engineering (@TwitterEng) 2014, 4月 17 Reactive Streams って？ Reactive Streams ”JVM 上でのノンブロッキングなバックプレッシャーを持つ非同期ストリーム処理の標準の提案”（公式サイトより）。 ざっくり言うと、既にある JVM ベースの様々な非同期ストリーム処理フレームワーク実装の共通部分を括りだして API 化、SPI 化しようというもの。最終的には JSR での標準化を目指
dockerなら5分で動く！ nginxのログをfluentdで集めてnorikraでストリーム分析 - Qiita
はじめに ようへいさんのポストを参考にしてdocker上でnginxとfluentdとnorikraを動かせたので、docker indexにイメージを掲載した。dockerのある環境ならあっという間に動くはず。 準備 dockerが動くこと ホスト側でfluentd用のファイルディスクリプタ設定を済ませていること 手順 norikraを動かす まずはログの集約先となるnorikraを動かす。 $ sudo docker run -p 26578:26578 -p 26571:26571 -p 24224:24224 -p 24224:24224/udp -d kazunori279/fluentd-norikra-server $ sudo docker ps CONTAINER ID IMAGE COMMAND CREATED STATUS PORTS NAMES 7874efdd2e
日テレが「Hulu」日本事業を取得 定額制動画配信に参入
日本テレビ放送網（日テレ）は2月28日、定額制動画配信サービス「Hulu」の日本市場向け事業を取得すると発表した。日テレは「Hulu」ブランドや技術のライセンスを米Huluから受け、日本でHulu事業を継続する。 日テレは、自社の人気番組などをHulu向けに限定配信するなどしてユーザー拡大を図る。 Huluは2011年9月に日本市場向けにサービスを開始。映画・ドラマ・アニメが月額980 円（税込）で見放題になる定額制動画配信サービスで、会員数は2013年の1年間で倍増したという。コンテンツパートナーはNHKやテレビ東京、TBSなどを含む約50社になり、1万3000本以上のコンテンツを配信している。 日テレは、米Hulu が会社分割により設立した新会社を子会社化することで日本向け事業を取得する。 日テレは既に「日テレオンデマンド」を展開しており、国内向けHuluの取得で定額制動画配信に参入す
任天堂がドワンゴ株の1.5％を取得
ドワンゴは11月15日、同社の発行済み株式の1.5％（61万2200株）を同日付で任天堂が取得したと発表した。1株当たり1864円（14日の終値）で取得し、取得価格は約11億4000万円。「両社の強みを持ち寄り、今までにないユニークなインターネット・エンターテインメントサービスの創造に取り組む」としている。 ドワンゴは任天堂の「Wii U」でニコニコ動画が見られるソフト「ニコニコ」を提供しているほか、ニコニコ生放送で任天堂の番組「ニンテンドーダイレクト」の番組を配信。今年4月にドワンゴが開いた「ニコニコ超会議2」には任天堂が特別協賛するなどし、「互いのビジネスの理解と信頼関係を築いてきた」という。 両社は「さらなる関係強化を図り、変化の激しいエンタテイメント業界で、今までにないユニークなインターネット・エンターテインメントサービスの創造に取り組む」としている。 ドワンゴは株主の多様化を進め
ExcelでLTSV読むよー - aike’s blog
LTSVが最近熱いですね。ログファイルのフォーマットはこれで決まり、みたいな。 とはいえ、業務システムだといまだに人月計算とスーツとExcelの世界なので、上司に提出する場合とかそのあたりの親和性をなんとかしたいところです。 そんなわけでExcelでLTSVを読めるようにVBAを書いてみました。これでログを罫線で囲ったりセルに色をつけたりできます！嬉しいのか、それ。 Attribute VB_Name = "LtsvLoader" ' ' LtsvLoader.bas ' ' This program is licensed under the MIT License. ' Copyright 2013, aike (@aike1000) ' Option Explicit Dim gHash As Object Dim gMaxColumn As Integer Sub LoadLTSV
1
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
GitHub - matz/streem: prototype of stream based programming language