From 60a3e4b595ab0dda1fa455d31a341bfa8695de88 Mon Sep 17 00:00:00 2001
From: spark_xp <spark_xp@d8c9ecd3-d47d-4367-8645-de82c00e513f>
Date: Fri, 26 Aug 2011 17:36:37 +0000
Subject: [PATCH] =?utf8?q?TweetSearchStreaming=E5=86=85=E3=81=AB=E3=80=81?=
 =?utf8?q?=E9=87=8D=E8=A4=87=E3=81=97=E3=81=9F=E4=BD=99=E8=A8=88=E3=81=AA?=
 =?utf8?q?=E3=82=B3=E3=83=BC=E3=83=89=E3=81=8C=E5=AD=98=E5=9C=A8=E3=81=97?=
 =?utf8?q?=E3=81=9F=E3=81=9F=E3=82=81=E5=89=8A=E9=99=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

git-svn-id: http://svn.sourceforge.jp/svnroot/nt-manager/NishioTweetManager/trunk@176 d8c9ecd3-d47d-4367-8645-de82c00e513f
---
 src/twitter/manage/TweetSearchStream.java | 17 +++++++++++------
 1 file changed, 11 insertions(+), 6 deletions(-)

diff --git a/src/twitter/manage/TweetSearchStream.java b/src/twitter/manage/TweetSearchStream.java
index 1e3309e..1a4286c 100644
--- a/src/twitter/manage/TweetSearchStream.java
+++ b/src/twitter/manage/TweetSearchStream.java
@@ -31,8 +31,6 @@ public class TweetSearchStream extends StatusAdapter implements Runnable{
 	private TwitterStream twitterStream = null;
 	//Filter query
 	private FilterQuery filter = null;
-	//登録されている検索ワード
-	private Set<String> filterWords = null;
 	//status stream
 	private StatusStream statusStream = null;
 	//Thread
@@ -41,8 +39,12 @@ public class TweetSearchStream extends StatusAdapter implements Runnable{
 	private TweetManager tweetManager = null;
 	//検索ワードに対応したリスナー
 	private Map<String, TweetStreamingListener> listeners = null;
+	//指定したユーザに対応したリスナー
+	private Map<Long, TweetStreamingListener> userListener = null;
 	//指定したワードの最終更新id
 	private Map<String, Long> lastUpdate = null;
+	//指定したユーザの最終更新id
+	private Map<Long, Long> userLastUpdate = null;
 
 	/**
 	 *
@@ -58,9 +60,10 @@ public class TweetSearchStream extends StatusAdapter implements Runnable{
 		this.twitterStream.setOAuthAccessToken(ac);
 
 		filter = new FilterQuery();
-		filterWords = new HashSet<String>();
 		listeners = new HashMap<String, TweetStreamingListener>();
+		userListener = new HashMap<Long, TweetStreamingListener>();
 		lastUpdate = new HashMap<String, Long>();
+		userLastUpdate = new HashMap<Long, Long>();
 	}
 
 	/**
@@ -68,7 +71,6 @@ public class TweetSearchStream extends StatusAdapter implements Runnable{
 	 * @param word
 	 */
 	public void addSearchWord(String word, TweetStreamingListener listener) {
-		filterWords.add(word);
 		listeners.put(word, listener);
 		updateFilter();
 	}
@@ -78,16 +80,19 @@ public class TweetSearchStream extends StatusAdapter implements Runnable{
 	 * @param word
 	 */
 	public void removeSearchWord(String word) {
-		filterWords.remove(word);
 		listeners.remove(word);
 		updateFilter();
 	}
 
+	public void addUserSearch(Long userid, TweetStreamingListener listener) {
+
+	}
+
 	/**
 	 * filterの更新
 	 */
 	private void updateFilter() {
-		String[] words = filterWords.toArray(new String[0]);
+		String[] words = listeners.keySet().toArray(new String[0]);
 		filter.track(words);
 		try {
 			if( statusStream != null ) {
-- 
2.11.0