yamasushi

#!/usr/bin/perl
# https://gist.github.com/yamasushi/311c5c424356abf645a2
use strict;
use warnings;
use utf8;
binmode STDIN,":utf8";
binmode STDOUT,":utf8";

while(<>){
  chomp;

yamasushi

gosh> (load "./twitterland-examples")
(-< yamasushi <@yamasushi : "まじです"> [@yamasushi : <@yamasushi : "つぶやき,はじめます">])
(-< null <@shuji : "まじで?"> [@null : <@yamasushi : "つぶやき,はじめます">])
(-< null <@yamasushi : "つぶやき,はじめます"> [@null : #f])
(-< shuji <@shuji : "まじで?"> [@shuji : #f])
(-< yamasushi <@yamasushi : "つぶやき,はじめます"> [@yamasushi : #f])
(-< null <@yamasushi : "まじです"> [@null : <@shuji : "まじで?">])
(-> shuji <@yamasushi : "まじです"> [@shuji : <@shuji : "まじで?">])
(-> yamasushi <@shuji : "まじで?"> [@yamasushi : <@yamasushi : "つぶやき,はじめます">])

yamasushi

!! Index - モジュール索引 : compat.norational --> compat.norational - 有理数のない算術演算 --> X
!! Index - モジュール索引 : dbi --> dbi - データベース非依存アクセス層 --> X
!! Index - モジュール索引 : gauche.dictionary --> gauche.dictionary - ディクショナリフレームワーク --> X
!! Index - モジュール索引 : text.progress --> text.progress - テキスト端末上でプログレスを表示する --> X
!! Index - モジュール索引 : text.sql --> text.sql - SQLのパーズと構築 --> X
!! Index - モジュール索引 : util.relation --> util.relation - リレーションフレームワーク --> X
!! Index - モジュール索引 : util.sparse --> util.sparse - 疎なデータコンテナ --> X
!! Index - モジュール索引 : util.trie --> util.trie - Trie --> X
!! Index - 手続きと構文索引 : <sql-parse-error> --> text.sql - SQLのパーズと構築 --> X
!! Index - 手続きと構文索引 : make-text-progress-bar --> text.progress - テキスト端末上でプログレスを表示する --> X

yamasushi

(use gauche.generator)
(use text.tr)

(define (generator-inverter) 
  (^[produce consume] (consume (generate produce) ) ) )

(define (pipeline inverter cmd-in cmd-out)
  (^[ g yield]
    (inverter
      (^[yield]

yamasushi

(use gauche.generator)
(use gauche.uvector)


(define (call-with-port-chunk port chunk-size size proc) 
  (let1 chunk (make-u8vector chunk-size)
    (cond
      [ (eqv? size 0) #t ]
      [ (not size) 
       (until (read-block! chunk port 0 chunk-size) eof-object? => len

yamasushi

(use gauche.uvector)

(define (uvector-slices u k)
  (let [(uvclass (class-of u))
        (l       (uvector-length u))]
    (receive (n r) (quotient&remainder l k)
      (let1 s (* n k)
        (let loop [(i s)
                   (d (if (= r 0) 
                        '() 

yamasushi

; http-getのパラメタ指定してhttp-get、procに仮想ポートを渡す。
(define (call-with-input-http http-param proc :key (queue-size 100) (buffer-size 8000) )
  (let1 inverter (mtport-inverter :queue-size queue-size :buffer-size buffer-size)
    (inverter
      (^[outp] (apply http-get (append http-param `(:sink ,outp :flusher ,(^ _ (flush outp) #t) ))))
      (^[inp]  (proc inp) ) ) ) )

yamasushi

; ポートの反転
(define-module port-inverter
  (use gauche.vport)
  (use gauche.generator)
  (use gauche.uvector)
  ;
  (use inverter)
  (export
    mtport-inverter
    ))

yamasushi

; イテレータ反転
(define-module inverter
  (use gauche.generator)
  (use util.stream)
  ;
  (use util.queue)
  (use gauche.threads)
  ;
  (export
    generator-inverter

yamasushi

#!/usr/bin/env gosh

(define (open-with-input-files files proc)
  (if (null? files)
    (proc (current-input-port) )
    (for-each 
      (lambda (f)
        (call-with-input-file f proc))
      files)))