@@ -171,45 +171,7 @@ public void openFile(DirectoryNode node) {
171171 }
172172
173173 protected void openCodeFile () {
174- /*<<<<<<< HEAD
175- Observable.create(new Observable.OnSubscribe<String>() {
176- @Override
177- public void call(Subscriber<? super String> subscriber) {
178- InputStream stream = null;
179- try {
180- stream = new FileInputStream(mNode.absolutePath);
181- } catch (FileNotFoundException e) {
182- e.printStackTrace();
183- }
184- if (stream == null) {
185- subscriber.onCompleted();
186- return;
187- }
188- final InputStream finalStream = stream;
189- String[] names = mNode.name.split("\\.");
190- String fileTypeName = names[names.length - 1];
191- if (BrushMap.isBlackFile(fileTypeName)) {
192- subscriber.onError(new Throwable("Can not open this file!"));
193- subscriber.onCompleted();
194- return;
195- }
196- String jsFile = BrushMap.getJsFileForExtension(fileTypeName);
197- if (jsFile == null) {
198- jsFile = "Txt";
199- }
200- StringBuilder sb = new StringBuilder();
201- StringBuilder localStringBuilder = new StringBuilder();
202- try {
203- BufferedReader localBufferedReader = new BufferedReader(
204- new InputStreamReader(finalStream, "UTF-8"));
205- for (; ; ) {
206- String str = localBufferedReader.readLine();
207- if (str == null) {
208- break;
209- }
210- localStringBuilder.append(str);
211- localStringBuilder.append("\n");*/
212- //=======
174+
213175 Observable .create ((Observable .OnSubscribe <String >) subscriber -> {
214176 InputStream stream = null ;
215177 try {
@@ -236,7 +198,7 @@ public void call(Subscriber<? super String> subscriber) {
236198 String str = localBufferedReader .readLine ();
237199 if (str == null ) {
238200 break ;
239- //>>>>>>> fix bug
201+
240202 }
241203 localStringBuilder .append (str );
242204 localStringBuilder .append ("\n " );
0 commit comments